org.springframework.messaging.tcp.reactor

Class ReactorNettyTcpConnection<P>

java.lang.Object

org.springframework.messaging.tcp.reactor.ReactorNettyTcpConnection<P>

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, TcpConnection<P>

public class ReactorNettyTcpConnection<P>
extends java.lang.Object
implements TcpConnection<P>

Reactor Netty based implementation of TcpConnection.

Since:

5.0

Author:

Rossen Stoyanchev

Field Summary

Fields

Modifier and Type	Field and Description
private <any>	closeProcessor
private ReactorNettyCodec<P>	codec
private NettyInbound	inbound
private NettyOutbound	outbound

Constructor Summary

Constructors

Constructor and Description
ReactorNettyTcpConnection(NettyInbound inbound, NettyOutbound outbound, ReactorNettyCodec<P> codec, <any> closeProcessor)

Method Summary

Modifier and Type	Method and Description
void	close() Close the connection.
void	onReadInactivity(java.lang.Runnable runnable, long inactivityDuration) Register a task to invoke after a period of read inactivity.
void	onWriteInactivity(java.lang.Runnable runnable, long inactivityDuration) Register a task to invoke after a period of write inactivity.
ListenableFuture<java.lang.Void>	send(Message<P> message) Send the given message.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

inbound

private final NettyInbound inbound

outbound

private final NettyOutbound outbound

codec

private final ReactorNettyCodec<P> codec

closeProcessor

private final <any> closeProcessor

Constructor Detail

ReactorNettyTcpConnection

public ReactorNettyTcpConnection(NettyInbound inbound,
                                 NettyOutbound outbound,
                                 ReactorNettyCodec<P> codec,
                                 <any> closeProcessor)

Method Detail

send

public ListenableFuture<java.lang.Void> send(Message<P> message)

Description copied from interface: TcpConnection

Send the given message.

Specified by:

send in interface TcpConnection<P>

Parameters:

message - the message

Returns:

a ListenableFuture that can be used to determine when and if the message was successfully sent

onReadInactivity

public void onReadInactivity(java.lang.Runnable runnable,
                             long inactivityDuration)

Description copied from interface: TcpConnection

Register a task to invoke after a period of read inactivity.

Specified by:

onReadInactivity in interface TcpConnection<P>

Parameters:

runnable - the task to invoke

inactivityDuration - the amount of inactive time in milliseconds

onWriteInactivity

public void onWriteInactivity(java.lang.Runnable runnable,
                              long inactivityDuration)

Description copied from interface: TcpConnection

Register a task to invoke after a period of write inactivity.

Specified by:

onWriteInactivity in interface TcpConnection<P>

Parameters:

runnable - the task to invoke

inactivityDuration - the amount of inactive time in milliseconds

close

public void close()

Description copied from interface: TcpConnection

Close the connection.

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface TcpConnection<P>